package yu.ac.bg.etf.kdp.klijent;

import java.io.*;
import java.net.*;

import yu.ac.bg.etf.kdp.klase.*;

public class ClientCheck extends Thread {

	String h;
	int p;
	Socket clientSocket;
	
	public ClientCheck (String host, int port) {
		h = host;
		p = port;
	}
	
	public void run () {
		try {
			// kacimo se na server
			Socket clientSocket = new Socket(h,p);
			// inicijalizujemo tokove podataka
			OutputStream os = clientSocket.getOutputStream();
			InputStream is = clientSocket.getInputStream();
			ObjectOutputStream outo = new ObjectOutputStream(os);
			outo.flush();
			ObjectInputStream ino = new ObjectInputStream(is);
			BufferedOutputStream bos = new BufferedOutputStream(os);
			BufferedInputStream bis = new BufferedInputStream(is);
			// protokol komunikacije
			outo.writeObject(new MsgTxt("cliRequest"));
			outo.flush();
			
			// primamo identifikator posla koji smo zapoceli
			MsgTxt = (MsgTxt)ino.readObject();
			jobId = job.getId();
			// zatvaramo tokove podataka
			outo.close();
			ino.close();
			clientSocket.close();
		} catch (UnknownHostException e2) {
			System.out.println("Unknown host..");
			return jobId;
		} catch (IOException e) {
			// TODO: handle exception
			System.out.println("Connection could not be established..");
			return jobId;
		} catch (ClassNotFoundException e1) {
			System.out.println("Class not found..");
			System.exit(1);
		}
	}
	
}
